#pragma once
#include "mqclient.h"
#include "amqp.h"
#include "amqp_tcp_socket.h"

namespace MqClient
{
class CRabbitMqConsumer : public CMqConsumer
{
public:
    virtual void Delete();

    bool Init();
    void Run();

public:
    amqp_connection_state_t _conn;
    bool                    _run;
};
};
